from kafka import KafkaConsumer
import time

while 1:
    consumer = KafkaConsumer(*['2206'], group_id='看一看')
    data = next(consumer)
    print(data.value)
    consumer.close()
    time.sleep(1)